# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.dummy_operator import DummyOperator
from jms.doris.jms_dwd.dwd_route_whole_city.dongbei import doris_jms_dwd__dwd_route_whole_city_from_whole_dongbei
from jms.doris.jms_dwd.dwd_route_whole_city.huabei import doris_jms_dwd__dwd_route_whole_city_from_whole_huabei
from jms.doris.jms_dwd.dwd_route_whole_city.huadong import doris_jms_dwd__dwd_route_whole_city_from_whole_huadong
from jms.doris.jms_dwd.dwd_route_whole_city.huanan import doris_jms_dwd__dwd_route_whole_city_from_whole_huanan
from jms.doris.jms_dwd.dwd_route_whole_city.huaxi import doris_jms_dwd__dwd_route_whole_city_from_whole_huaxi
from jms.doris.jms_dwd.dwd_route_whole_city.huazhong import doris_jms_dwd__dwd_route_whole_city_from_whole_huazhong
from jms.doris.jms_dwd.dwd_route_whole_city.xibei import doris_jms_dwd__dwd_route_whole_city_from_whole_xibei
from jms.doris.jms_dwd.dwd_route_whole_city.xinan import doris_jms_dwd__dwd_route_whole_city_from_whole_xinan
from jms.doris.jms_dwd.dwd_route_whole_city.local_city import doris_jms_dwd__dwd_route_whole_city_from_local_city
from jms.doris.jms_dwd.dwd_route_whole_city.route_whole_reorganized import \
    doris_jms_dwd__dwd_route_whole_city_reorganized
from jms.doris.jms_dwd.dwd_route_whole_city.route_whole_reorganized import \
    doris_jms_dwd__dwd_route_whole_city_reorganized
from jms.time_sensor.time_after_05_00 import time_after_05_00
from jms.time_sensor.time_after_05_30 import time_after_05_30
from jms.doris.jms_dwd.dwd_route_whole import doris_jms_dwd__route_whole
from jms.dm.route.dm_route_reorganized import dm__dm_route_whole_reorgnized

doris_jms_dwd__route_whole_city = DummyOperator(
    task_id='doris_jms_dwd__dwd_route_whole_city',
    pool='unlimited_pool',
    email=['zhangqinglin@jtexpress.com','yl_bigdata@yl-scm.com'],
    priority_weight=0,
    sla=timedelta(hours=18),
)

doris_jms_dwd__dwd_route_whole_city_from_whole_dongbei << [time_after_05_00, doris_jms_dwd__route_whole]
doris_jms_dwd__dwd_route_whole_city_from_whole_huabei << [time_after_05_30, doris_jms_dwd__route_whole]
doris_jms_dwd__dwd_route_whole_city_from_whole_huadong << [time_after_05_30, doris_jms_dwd__route_whole]
doris_jms_dwd__dwd_route_whole_city_from_whole_huanan << [time_after_05_30, doris_jms_dwd__route_whole]
doris_jms_dwd__dwd_route_whole_city_from_whole_huaxi << [time_after_05_00, doris_jms_dwd__route_whole]
doris_jms_dwd__dwd_route_whole_city_from_whole_huazhong << [time_after_05_00, doris_jms_dwd__route_whole]
doris_jms_dwd__dwd_route_whole_city_from_whole_xibei << [time_after_05_00, doris_jms_dwd__route_whole]
doris_jms_dwd__dwd_route_whole_city_from_whole_xinan << [time_after_05_00, doris_jms_dwd__route_whole]
doris_jms_dwd__dwd_route_whole_city_from_local_city << [time_after_05_00, doris_jms_dwd__route_whole]

doris_jms_dwd__dwd_route_whole_city_reorganized << dm__dm_route_whole_reorgnized

doris_jms_dwd__route_whole_city << doris_jms_dwd__dwd_route_whole_city_reorganized << [
    doris_jms_dwd__dwd_route_whole_city_from_whole_dongbei,
    doris_jms_dwd__dwd_route_whole_city_from_whole_huabei,
    doris_jms_dwd__dwd_route_whole_city_from_whole_huadong,
    doris_jms_dwd__dwd_route_whole_city_from_whole_huanan,
    doris_jms_dwd__dwd_route_whole_city_from_whole_huaxi,
    doris_jms_dwd__dwd_route_whole_city_from_whole_huazhong,
    doris_jms_dwd__dwd_route_whole_city_from_whole_xibei,
    doris_jms_dwd__dwd_route_whole_city_from_whole_xinan,
    doris_jms_dwd__dwd_route_whole_city_from_local_city, ]
